package com.hg.normal.producer;

import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;

/**
 * created by skh on 2019/12/14
 */
public class Producer {
	public static void main(String[] args) throws Exception {
		//创建一个消息生产者,并设置一个消息生产者组
		DefaultMQProducer producer = new DefaultMQProducer("producer_group");

		//指定 NameServer 地址
		producer.setNamesrvAddr("47.98.129.125:9876");

		//初始化 Producer ，在整个应用生命周期中只需要初始化一次
		producer.start();

		for (int i = 0; i < 5; i++) {
			//创建一个消息对象,指定其主题,标签和消息内容
			Message message = new Message(
					"topic_example_java",
					"TageA",
					"hello mq".getBytes()
			);

			//发送消息并返回结果
			SendResult result = producer.send(message);
			System.out.println("result = " + result);
		}

		//一旦生产者实例不再被使用,则将其关闭,包括清理资源,关闭网络连接等
		producer.shutdown();

	}
}
